package com.moli.iov.gateway.server.model;


import java.io.Serializable;

/**
 * @author fudh
 * @ClassNmme KafkaSendData
 * @date 2019/5/16 15:11
 * @Description: kafka数据封装对象
 */
public class KafkaSendData  implements Serializable {

    /**
     * kafka主题
     */
    private String topic;

    /**
     * kafka key,这里面是vin
     */
    private String vin;

    public KafkaSendData(String topic, String vin, Object payLoad) {
        this.topic = topic;
        this.vin = vin;
        this.payLoad = payLoad;
    }

    /**
     * 有效数据，这里面只有两种类型，当topic是车辆上下线的时候为VehicleOnLineDto类型；其他时候为ReqStreamData类型
     */


    private Object payLoad;


    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getVin() {
        return vin;
    }

    public void setVin(String vin) {
        this.vin = vin;
    }

    public Object getPayLoad() {
        return payLoad;
    }

    public void setPayLoad(Object payLoad) {
        this.payLoad = payLoad;
    }
}
